import java.util.logging.Logger;

//通过socket连接到broker
public class ConsumerImple implements Consumer{
    String name;
    public ConsumerImple(String name){
        this.name = name;
    }

    @Override
    public void getMessage() {

    }

    @Override
    public void getTopic() {

    }

    @Override
    public void getBroadcast() {

    }
}
